package vip.ifmm.lehouse.mq.service.api;

import org.apache.rocketmq.client.producer.SendResult;
import vip.ifmm.lehouse.common.dto.ServerResponse;

/**
 * 消息队列服务接口
 *
 * @author Red
 * email: 1318944013@qq.com
 * date: 2019/6/17 21:36
 */

public interface RocketMqService {

    // 默认生产方式
    ServerResponse<SendResult> send(String topic, String tags, String msg);

    // 顺序生产者
    ServerResponse <SendResult> sendOrderly(String topic, String tags,
                       String msg, Integer queueIndex);

}
